package com.atguigu.realtime.app.dwd;

import com.atguigu.realtime.app.BaseApp;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author lizhenchao@atguigu.cn
 * @Date 2021/2/6 22:01
 */
public class Test extends BaseApp {
    public static void main(String[] args) {
        new Test().init(1, "a", "test");
        
    }
    @Override
    protected void run(StreamExecutionEnvironment env, DataStreamSource<String> sourceStream) {
        sourceStream.print();
    }
}
